package com.yang.consumer.integration;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class OrderListener {
    @StreamListener(Barista.INPUT)
    @SendTo(Barista.OUTPUT)
    public long listenFinishedOrders(Long id) {
        log.info("消费端接收到数据：{}", id);
        return 567;
    }
}
